package com.hw.one.dam2.dao;

import java.util.List;
import java.util.Map;

import com.hw.one.dam2.entity.PollutionIndustryEntity;
import com.hw.one.dam2.param.PollutionIndustryParam;

/**
 * 工业污染源 Mongo数据 Dao
 * 
 * @author admin
 *
 */
public interface IIndustryPollutionDao {
	/**
	 * 根据站点编码列表和时间段，查询工业污染源数据集合
	 * @param paramPO
	 * @return
	 */
	List<PollutionIndustryEntity> findIndustryPollutionBySiteCodeAndTime(PollutionIndustryParam paramPO,String collectionName);

	/**
	 * 根据工业源公司编码和排口编码，获取最新小时数据
	 * @param siteCodeList
	 * @param outputCodeList
	 * @return
	 * @throws Exception 
	 */
	@SuppressWarnings("rawtypes")
	List<Map> findPollutionNewHourDataByPSCodeAndOutputCodes(List<String> siteCodeList, List<String> outputCodeList) throws Exception;

	/**
	 * 获取指定公司的最近12小时的小时数据
	 * @param siteCode
	 * @param outputCodeList 
	 * @return
	 * @throws Exception 
	 */
	@SuppressWarnings("rawtypes")
	List<Map> findLast12HourIndustryHourDataBySiteCode(String siteCode, List<String> outputCodeList) throws Exception;

	/**
	 * 根据站点编码和时间段,查询工业污染源数据集合
	 * @author 李亚坤
	 * @createtime 2017年3月21日14:24:10
	 * @param paramPO
	 * @param collectionName
	 * @return
	 */
	List<Map> findIndustryPollutionBySiteCodeAndSDTime(PollutionIndustryParam paramPO,String collectionName);
}
